import pymysql

# 2) 使用 PyMySQL 库建立与 MySQL 的连接，并返回一个 connector 对象。connect（）方法
# 中的参数介绍如下：host 为主机名，user 为连接 MySQL 的用户名，password 为 MySQL 的连
# 接密码，port 为 MySQL 的端口号。
connector = pymysql.connect(host='localhost', user='root', password='root', port=3306)

# 3) 使用 connector 对象的 cursor() 方法建立对 MySQL 的操作游标。
cursor = connector.cursor()

# 4) 使用 executes 方法，以SELECT VERSION()字符串作为参数，执行游标。其目的就是执行 SELECT VERSION()方法获得的返回值。SELECT VERSION()方法是获得当前MySQL 的版本信息。
cursor.execute('SELECT VERSION()')

# 5) 通过 fetchone()方法获取步骤 4 中执行游标 cursor 后的返回值的第一行。
data = cursor.fetchone()

# 6) 输出数据库版本信息。
print('database version:', data)

# 7) 使用cursor 的execute。方法，力口入 SQL 语句实现对MySQL 的操作。这里使用 “CREATE DATABASE + 数据库名” 的方式创建一个名为 test 的数据库，并使用向Bmb4 作为字符集。
cursor.execute("CREATE DATABASE test DEFAULT CHARACTER SET utf8mb4")

# 8) 在对数据库操作结束之后，必须要关闭 connector 对象指向的 MySQL 连接通道，释放有关资源。
connector.close()